package com.yifeng.repo.flink.data.transport.config;

import java.io.Serializable;

import lombok.Data;

@Data
public class KafkaConfig implements Serializable {

	private static final long serialVersionUID = 1L;
	
	/**
	 * kafka的服务器地址
	 */
	private String bootstrapServers;
	
	/**
	 * kafka的用户名
	 */
	private String username;
	
	/**
	 * kafka的密码
	 */
	private String password;
	
	private boolean isAuthPassword;
	
	/**
	 * kafka是否按hash分区
	 */
	private boolean partitionByHash;
	
	/**
	 * kafka的分区数量
	 */
	private int partitionSize;
	
	/**
	 * kafka的topic
	 */
	private String topic;

	/**
	 * kafka的消防组
	 */
	private String groupId;
	/**
	 * kafka的startingOffset
	 */
	private String startingOffset;

}
